﻿using System;
using System.Collections.Generic;
using System.Text;
using Confluent.Kafka;


namespace BCGPS.DataRealy.Service
{
    public class ReadConfluentKafkaConsumer
    {
        public ReadConfluentKafkaConsumer()
        {
            var conf = new ConsumerConfig
            {
                BootstrapServers = ConfigurationManager.AppSettings["Kafka:BrokerList"],
                AutoOffsetReset = AutoOffsetReset.Earliest,
            };
            var consumer = new ConsumerBuilder<Ignore, string>(conf).Build();
 
        }

    }
}
